package com.share.common.rabbit.model;

import lombok.Data;

import java.util.List;
import java.util.Map;

@Data
public class CanalSyncMessage {
    private List<Map<String, Object>> data;
    private String database;
    private Long es;
    private Long id;
    private Boolean isDdl;
    private Map<String, String> mysqlType;
    private List<Map<String, Object>> old;
    private List<String> pkNames;
    private String sql;
    private Map<String, Integer> sqlType;
    private String table;
    private Long ts;
    private String type; // 对应 Canal 的 EventType (INSERT, UPDATE, DELETE)
}
